//package com.ruoyi.common.kafka;
//
//import org.testng.annotations.Test;
//
//import java.util.concurrent.ExecutionException;
//
///**
// * @Author: 倚天照海
// */
//public class Main {
//    MyProducer myProducer = new MyProducer();
//
//    MyConsumer myConsumer = new MyConsumer();
//
//    @Test
//    public void produceTest() {
//        produceData();
//    }
//
//    @Test
//    public void consumeTest() {
//        consumeData();
//    }
//
//    private void produceData() {
////        MyProducer myProducer = new MyProducer();
//        try {
//            myProducer.produce();
//        } catch (ExecutionException | InterruptedException e) {
//            e.printStackTrace();
//        }
//    }
//
//    private void consumeData() {
////        MyConsumer myConsumer = new MyConsumer();
//        myConsumer.consume();
//    }
//}
